package cn.edu.flink.scala.tutorial.map

import org.apache.flink.api.common.functions.FlatMapFunction
import org.apache.flink.streaming.api.scala.{StreamExecutionEnvironment, createTypeInformation}
import org.apache.flink.util.Collector
import org.apache.flink.api.scala._

object Test {
  def main(args: Array[String]): Unit = {
    val env = StreamExecutionEnvironment.getExecutionEnvironment

    // nc -lk 8088
    val source = env.socketTextStream("101.42.90.223", 8088)

    source.print()

    env.execute("Test")
  }
}


